package com.sun.kafka.service.impl;

import com.sun.kafka.service.TopicService;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;

@Service
public class TopicServiceImpl implements TopicService {
    @Override
    public List<String> listTopics() {
        // 模拟查询数据库
        List<String> list = new ArrayList<>();
        list.add("batch1");
        list.add("batch2");
        return list;
    }
}
